package com.bsj.power.pls.web;

import com.bsj.power.pls.queue.MsgQueue;
import com.bsj.power.pls.queue.TagAlarmMsgQueue;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author LiJiaXin
 * @version 1.0.0
 * @description YapiController
 * @time 2024/6/5 17:11
 */
@Slf4j
@RestController
@RequestMapping("/pls/path")
public class YapiController {

    @Autowired
    private TagAlarmMsgQueue tagAlarmMsgQueue;

    @Autowired
    private MsgQueue msgQueue;

//    @SaIgnore
//    @PostMapping("/test")
//    public JsonResult test(@RequestBody JSONObject jsonObject) {
//        //14表示标签相关消息
//        Integer type = jsonObject.getInteger("type");
//        String data = jsonObject.getString("data");
//        if (type == 7) {
//            TagAlarmMsgDTO tagAlarmMsgDTO = JSONObject.parseObject(data, TagAlarmMsgDTO.class);
//            //电子围栏告警消息
//            if (tagAlarmMsgDTO != null && tagAlarmMsgDTO.getType() == 10) {
//                try {
//                    log.info("接收到电子围栏报警信息：{}", tagAlarmMsgDTO);
//                    tagAlarmMsgQueue.push(tagAlarmMsgDTO);
//                } catch (Exception e) {
//                    log.error("tagAlarmMsgQueue写入数据失败:" + ExceptionUtil.getStackStr(e));
//                }
//            }
//        }
//        return JsonResult.success();
//    }

}
